package com.yc.mvplib.Retrofit.net;

import android.widget.Toast;

import com.yc.mvplib.R;
import com.yc.mvplib.utlis.NetworkUtil;

import butterknife.internal.Utils;
import io.reactivex.Observable;
import io.reactivex.ObservableSource;
import io.reactivex.ObservableTransformer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;

/**
 * 描述：Rx统一请求
 * 创建者：  Churck
 * 创建时间：2017/12/8 17:10
 * 修改者： Churck
 * 修改时间：2017/12/8 17:10
 * 版 本：v1.0
 */

public class RxSchedulers {
    public static <T> ObservableTransformer<T, T> compose() {
        return new ObservableTransformer<T, T>() {
            @Override
            public ObservableSource<T> apply(Observable<T> observable) {
                return observable
                        .subscribeOn(Schedulers.io())//在工作线程请求网络
                        .observeOn(AndroidSchedulers.mainThread());//在主线程处理结果
            }
        };
    }

}
